Spring Cloud Alibaba 最新版本(基于Spring Boot 3.1.0)整合完整使用及与各中间件集成 | 您所在的位置:网站首页 › spring boot 最新版 › Spring Cloud Alibaba 最新版本(基于Spring Boot 3.1.0)整合完整使用及与各中间件集成 |
目录 前言 源码地址 官方中文文档 使用版本 spring Spring Boot 3.1.0 中间件 使用到的组件与功能 环境安装 虚拟机 nexus nacos 集成过程 工程搭建 父工程搭建 子工程 服务集成 nacos集成 配置文件 服务注册与发现-discovery 服务注册 启动 服务发现 测试 配置管理-config 新增配置 测试 Sentinel集成 官方文档 服务端安装 集成步骤 配置修改 测试 SpringCloud Gateway集成 配置文件修改 参数说明 测试 拓展 SpringCloud OpenFeign集成 集成过程 测试 Seata 整合实现分布式事务 概念介绍及Server搭建 集成过程 数据库脚本 业务表脚本 代码模块改造 POM依赖 配置文件 详细代码 client集成openFeign实现远程调用 测试 Knife4J整合gateway接口文档 需求 官方文档 集成 网关模块修改 业务模块修改 测试 Rocketmq消息队列集成 服务安装 前置准备 Spring Cloud Stream基础 配置文件修改 业务代码 provider consumer 测试 进阶 消息丢失问题 tag与key的设置 Sleuth+Zipkin集成分布式链路追踪 zipkin可视化服务安装 业务集成 问题及大坑 Micrometer Tracing 集成实现分布式链路追踪 资料 集成 依赖 配置修改 测试 Spring Boot Admin 集成实现服务监控 前置准备 配置修改 父工程 admin工程 客户端consumer 测试 效果 集成Spring Authorization Server 与Spring Security Oauth2.1统一认证 过程 前言只介绍如何集成及使用,概念性的东西就不细说了。慢慢更新 源码地址代码我传到了gitHub上,地址如下: ricardo-m-yu/spring-cloud-alibaba (github.com) 官方中文文档spring-cloud-alibaba/README-zh.md at 2022.x · alibaba/spring-cloud-alibaba · GitHub 使用版本 spring我这边使用的都是最新版 spring.cloud.alibaba.version2022.0.0.0-RC2spring.cloud.version2022.0.0spring.boot.version3.1.0spring-cloud-alibaba、spring-cloud、springboot 三者的版本关系说明 https://github.com/alibaba/spring-cloud-alibaba/wiki/%E7%89%88%E6%9C%AC%E8%AF%B4%E6%98%8E Spring Boot 3.1.0因为需要使用新版本的springboot及spring.cloud.alibaba。 springboot3.1x版本特性: 调整 JDK 基线到 17 版本,兼容 JDK19,即最低的JDK要求17将 Java EE 依赖迁移到 Jakarta EE;比如 javax.servlet.Servlet 已经成了 jakarta.servlet.Servlet支持应用使用 GraalVM 技术生成原生镜像,取代了之前实验性质的 Spring Native 项目,让 Spring Boot 应用直接迈向 GraalVM;使用 Micrometer 和 Micrometer Tracing 提升了应用可观测性,比如 sleuth已经废弃,使用了Micrometer TracingDocker Compose的支持ssl的配置授权服务器的自动配置: Spring Authorization Server 中间件组件关系 使用到的组件与功能 服务注册与发现:Nacos 分布式事务:Seata网关:Spring Cloud Gateway服务调用:OpenFeign鉴权:Spring Authorization Server 、Oauth2.1消息队列:rocketmq限流、熔断:sentinel链路追踪:Micrometer Tracing接口文档:knife4j 环境安装 虚拟机我是用的VMware虚拟机里面跑的。 具体怎么装,看下面 (312条消息) VMware16安装 CentOS7_ricardo.M.Yu的博客-CSDN博客 nexus我这边搭建了一个nexus maven私服 (310条消息) docker-compose 搭建maven私服 nexus与配置_ricardo.M.Yu的博客-CSDN博客 nacos(310条消息) docker-compose安装nacos 2.2.1及配置_ricardo.M.Yu的博客-CSDN博客 集成过程 工程搭建我这边使用的是springboot多模块项目,最终效果如下 父工程搭建POM文件 4.0.0 org.example cloud-alibaba 1.0-SNAPSHOT pom common file auth gateway admin data biz log consumer 17 17 UTF-8 UTF-8 2022.0.0.0-RC2 2022.0.0 3.1.0 2.5.1 1.18.20 1.2.73 org.springframework.boot spring-boot-starter-parent 3.1.0 org.springframework.boot spring-boot-dependencies ${spring.boot.version} pom import org.springframework.cloud spring-cloud-dependencies ${spring.cloud.version} pom import com.alibaba.cloud spring-cloud-alibaba-dependencies ${spring.cloud.alibaba.version} pom import de.codecentric spring-boot-admin-starter-server ${spring.boot.admin.version} de.codecentric spring-boot-admin-starter-client ${spring.boot.admin.version} org.projectlombok lombok ${lombok.version} com.alibaba fastjson ${fastjson.version} prod prod true dev dev org.springframework.boot spring-boot-maven-plugin none execute repackage 子工程 服务集成 nacos集成部分可以参考官方的示例 Nacos Spring Cloud 快速开始 配置文件这边我定义了4组配置文件,说一下他们的作用: 引导类配置; bootstrap.yaml:定义当前生效的配置 spring: profiles: active: devbootstrap-dev.yaml:定义引导类当前生效的参数 spring: cloud: nacos: server-addr: http://192.168.1.115:8108/ discovery: group: dev应用级配置: application.yaml 应用级别的基础配置 logging: level: root: info com: sy: debugapplication-dev.yaml 定义应用的名称以及端口等信息 server: port: 9110 spring: application: name: biz 服务注册与发现-discovery 服务注册引入依赖 com.alibaba.cloud spring-cloud-starter-alibaba-nacos-discovery org.springframework.cloud spring-cloud-starter-loadbalancer 启动启动后,查看nacos控制台服务列表,已经能看到这个实例 服务发现需要在新建一个consumer服务,来测试 分别在两个模块建两个controller, biz模块下: @RestController @RefreshScope @RequestMapping("/") public class BizController { @GetMapping(value = "/echo/{string}") public String echo(@PathVariable String string) { return "Hello Nacos Discovery " + string; } }consumer模块下 @Slf4j @RestController @RequestMapping("/") public class ConsumerController { @Autowired private RestTemplate restTemplate; @Autowired private LoadBalancerClient loadBalancerClient; @Value("${spring.application.name}") private String appName; @GetMapping("/echo/app-name") public String echoAppName() { //使用 LoadBalanceClient 和 RestTemolate 结合的方式来访问 ServiceInstance serviceInstance = loadBalancerClient.choose("biz"); String url = String.format("http://%s:%s/echo/%s", serviceInstance.getHost(), serviceInstance.getPort(), appName); System.out.println("request url:" + url); String result = restTemplate.getForObject(url, String.class); log.info("result -> {}", result); return result; } } 测试用consumer下的http测试接口,发现已经能正常返回数据,appName即为consumer 配置管理-config配置管理测试,主要集成从nacos拉取公共配置并测试, 新增配置biz模块下新增依赖和配置文件 com.alibaba.cloud spring-cloud-starter-alibaba-nacos-config增加配置中心config配置,文件扩展为yaml spring: cloud: nacos: server-addr: http://192.168.1.115:8108/ discovery: group: dev #配置中心 config: server-addr: http://192.168.1.115:8108/ group: dev file-extension: yaml # 共享配置 # shared-configs: # - data-id: application-dev.yaml # group: dev # extension-configs: # - dataId: test01.yml # group: dev application: name: biznacos web页面配置列表新增一个配置,命名格式和group要对,dataId格式 ${spring.application.name}-${profile}.${file-extension:properties} 示例: biz-dev.yaml 我这边建了个示例 测试修改 BizController 增加方法: @Value("${username}") private String username; @GetMapping("/get") public String get() { return username; }http测试:可以看到username的值已经为 nacos的设置值 Sentinel集成 官方文档quick-start | Sentinel (sentinelguard.io) demo spring-cloud-alibaba/readme-zh.md at 2022.x · alibaba/spring-cloud-alibaba · GitHub 服务端安装详细的看下面文章 (305条消息) Spring Cloud Alibaba 之 sentinel-dashboard 安装及docker-compose镜像制作_ricardo.M.Yu的博客-CSDN博客 集成步骤 配置修改pom文件,新增依赖 com.alibaba.cloud spring-cloud-starter-alibaba-sentinel修改bootstrap-dev.yaml, 增加 sentinel相关配置, dashboard即为 sentinel控制台的地址, port为当前项目需要暴露的接口,与控制台通信使用 spring: cloud: nacos: server-addr: http://192.168.1.115:8108/ discovery: group: dev sentinel: transport: dashboard: localhost:9988 port: 8899 测试启动biz项目,调用下之前的 get接口,然后刷新 sentinel控制台,已经看到了biz的相关监控数据,其他详细的功能,可以看官方文档 SpringCloud Gateway集成nacos整合Spring Cloud Gateway 实现路由与服务动态发现 配置文件修改pom集成 org.springframework.cloud spring-cloud-starter-gateway com.alibaba.cloud spring-cloud-alibaba-sentinel-gatewaygateway模块配置文件增加 spring: main: web-application-type: reactive cloud: nacos: server-addr: http://192.168.1.115:8108/ discovery: group: dev sentinel: transport: dashboard: 192.168.1.115:9988 port: 8899 gateway: # discovery: # locator: # enabled: true routes: - id: consumer-service uri: https://www.qq.com predicates: - Method=GET,POST - Path=/consumer-service/** # - id: biz # uri: http://192.168.1.125:9110 # predicates: # - Method=GET,POST # - Path=/biz/** - id: biz uri: lb://biz predicates: - Method=GET,POST - Path=/biz/** 参数说明id:路由的ID,名称可以随意定义,但必须保证唯一 uri: 目标URI,路由到微服务的地址 上面的配置中第一个是直接转发到 qq 网站; 下面是 采用 LoadBalanceClient 方式请求,以 lb:// 开头,后面的是注册在 Nacos 上的服务名 order:路由的优先级,数字越小,优先级越高。 predicates:配置断言,通过PredicateDefinition类进行接收配置 discovery: locator: # 是否与服务发现组件结合,通过serviceId转发到具体服务实例 enabled: true # 是否开启基于服务发现的路由规则 如: 上面的方式中:lb://biz 配置即可找到 nacos中的biz服务 测试postman测试 已经收到了回复的消息 拓展关于路由规则,过滤器、自定义的规则等知识,详细见官网。 Spring Cloud Gateway SpringCloud OpenFeign集成 集成过程引入依赖 org.springframework.cloud spring-cloud-starter-openfeignbiz模块新增一个API @GetMapping(value = "/info") public Map getInfo(@RequestParam String username) { HashMap map = new HashMap(); map.put("username", username); map.put("password", "123456"); return map; }consumer模块启动类增加注解@EnableFeignClients @EnableFeignClients @EnableDiscoveryClient @SpringBootApplication public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } }consumer模块新增一个 client,意思是调用biz模块的上面方法 @Component @FeignClient(value = "biz") public interface BizClient { @GetMapping("/biz/info") Object getInfo(@RequestParam String username); }consumer模块controller新增一个方法供调用 @Resource private BizClient bizClient; @GetMapping("/username") public Object getUserInfo(@RequestParam String username) { return bizClient.getInfo(username); } 测试postmant调用 consumer的方法,效果如下: 可以看到已经成功调用 Seata 整合实现分布式事务Seata 是 阿里巴巴 开源的 分布式事务中间件,以 高效 并且对业务 0 侵入 的方式,解决 微服务 场景下面临的分布式事务问题。 概念介绍及Server搭建有些麻烦,放在了另一处,链接 (319条消息) Spring Cloud Alibaba 整合Seata 之概念介绍及Seata-server搭建_ricardo.M.Yu的博客-CSDN博客 集成过程 数据库脚本我使用的是seata默认的AT模式,可以通过注解的方式无侵入的方式实现集成,需要额外的一张表如下 Seata AT 模式 需要使用到 undo_log 表。 -- 注意此处0.3.0+ 增加唯一索引 ux_undo_log CREATE TABLE `undo_log` ( `id` bigint(20) NOT NULL AUTO_INCREMENT, `branch_id` bigint(20) NOT NULL, `xid` varchar(100) NOT NULL, `context` varchar(128) NOT NULL, `rollback_info` longblob NOT NULL, `log_status` int(11) NOT NULL, `log_created` datetime NOT NULL, `log_modified` datetime NOT NULL, `ext` varchar(100) DEFAULT NULL, PRIMARY KEY (`id`), UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`) ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8; 业务表脚本几个测试表,提供测试 SET NAMES utf8mb4; SET FOREIGN_KEY_CHECKS = 0; -- ---------------------------- -- Table structure for account_tbl -- ---------------------------- DROP TABLE IF EXISTS `account_tbl`; CREATE TABLE `account_tbl` ( `id` int(11) NOT NULL AUTO_INCREMENT, `user_id` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL, `money` int(11) NULL DEFAULT 0, PRIMARY KEY (`id`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT = 3 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic; -- ---------------------------- -- Records of account_tbl -- ---------------------------- INSERT INTO `account_tbl` VALUES (11, '1001', 981); -- ---------------------------- -- Table structure for order_tbl -- ---------------------------- DROP TABLE IF EXISTS `order_tbl`; CREATE TABLE `order_tbl` ( `id` int(11) NOT NULL AUTO_INCREMENT, `user_id` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL, `commodity_code` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL, `count` int(11) NULL DEFAULT 0, `money` int(11) NULL DEFAULT 0, PRIMARY KEY (`id`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic; -- ---------------------------- -- Records of order_tbl -- ---------------------------- INSERT INTO `order_tbl` VALUES (6, '1001', '2001', 1, 5); INSERT INTO `order_tbl` VALUES (8, '1001', '2001', 1, 5); INSERT INTO `order_tbl` VALUES (9, '1001', '2001', 1, 5); INSERT INTO `order_tbl` VALUES (10, '1001', '2001', 1, 5); -- ---------------------------- -- Table structure for stock_tbl -- ---------------------------- DROP TABLE IF EXISTS `stock_tbl`; CREATE TABLE `stock_tbl` ( `id` int(11) NOT NULL AUTO_INCREMENT, `commodity_code` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL, `count` int(11) NULL DEFAULT 0, PRIMARY KEY (`id`) USING BTREE, UNIQUE INDEX `commodity_code`(`commodity_code`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic; -- ---------------------------- -- Records of stock_tbl -- ---------------------------- INSERT INTO `stock_tbl` VALUES (2, '2001', 11107); 代码模块改造之前的biz模块修改为provider模块,新建1个新的父模块 biz,并在下面建4个子模块 biz-account,biz-order,biz-stock,biz-web,新的结构如下 POM依赖在biz父模块引入依赖 com.sy common 1.0-SNAPSHOT mysql mysql-connector-java org.mybatis.spring.boot mybatis-spring-boot-starter com.alibaba druid-spring-boot-starter com.alibaba.cloud spring-cloud-starter-alibaba-seata子模块pom,这里我为了方便,使用了 knife4j的最新接口文档,支持springboot3.0 4.0.0 com.sy biz 1.0-SNAPSHOT biz-web 17 17 UTF-8 com.github.xiaoymin knife4j-openapi3-jakarta-spring-boot-starter 4.1.0 配置文件每个文件都添加seata的配置,如下 spring: cloud: nacos: server-addr: http://192.168.1.115:8108/ discovery: group: dev sentinel: transport: dashboard: 192.168.1.115:8109 port: 8900 application: name: provider seata: enabled: true application-id: ${spring.application.name} tx-service-group: my-tx-group service: vgroup-mapping: my-tx-group: seata-server grouplist: seata-server: 192.168.1.115:8091 详细代码完整的就不弄了,到时下下来源码去看,主要说几个重要的 controller,提供接口 @RequestMapping("/api/business") @RestController public class BusinessController { @Autowired private BusinessService businessService; /** * 购买下单,模拟全局事务提交 * * @return */ @GetMapping("/purchase/commit") public Boolean purchaseCommit(HttpServletRequest request) { businessService.purchase("1001", "2001", 1); return true; } /** * 购买下单,模拟全局事务回滚 * * @return */ @GetMapping("/purchase/rollback") public Boolean purchaseRollback() { try { businessService.purchase("1002", "2001", 1); } catch (Exception e) { e.printStackTrace(); return false; } return true; } }service提供多个服务的接口调用,方便测试 @Slf4j @Service public class BusinessService { @Autowired private StockClient stockClient; @Autowired private OrderClient orderClient; /** * 减库存,下订单 * * @param userId * @param commodityCode * @param orderCount */ @GlobalTransactional public void purchase(String userId, String commodityCode, int orderCount) { log.info("purchase begin ... xid: " + RootContext.getXID()); stockClient.deduct(commodityCode, orderCount); orderClient.create(userId, commodityCode, orderCount); } } client集成openFeign实现远程调用 @FeignClient(value = "biz-stock") public interface StockClient { @GetMapping("/api/stock/deduct") Object deduct(@RequestParam String commodityCode, @RequestParam Integer count); }mapper及xml文件不一一列出了,下载源码去看,结构如下 knife4j配置 @Configuration @EnableKnife4j public class SwaggerConfiguration { @Value("${spring.application.name}") private String appName; @Bean public OpenAPI customOpenAPI() { return new OpenAPI() .info(new Info() .title(appName + "系统API") .version("1.0") .description( "Knife4j集成springdoc-openapi示例") .termsOfService("http://doc.xiaominfo.com") .license(new License().name("Apache 2.0") .url("http://doc.xiaominfo.com"))); } } 测试打开biz-web的接口 http://192.168.1.125:9203/doc.html 测试 如果打断点,undo_log这个表会有相关的信息 事务完成后,会删除 biz-web调用控制台效果图 seata-server端打印的日志 Knife4J整合gateway接口文档 需求因为开发需求,需要整合各个服务的接口文档,发现了knife4j最新版本(2023.3)出来了一个好用的插件,可以方便整合 SpringCloud Gateway 与各个业务服务的接口文档,不需要之前我们再硬编码写各种过滤器和拦截器去手动整合了。 官方文档Spring Cloud Gateway网关聚合 | Knife4j (xiaominfo.com) 集成 网关模块修改在之前的网关模块新增依赖 com.github.xiaoymin knife4j-gateway-spring-boot-starter 4.1.0修改网关模块的 bootstrap-dev.yaml配置文件,增加 knife4j的配置 excluded-services:即为排除的网关服务的名称, 此处 strategy: discover 是依赖 nacos的注册中心的服务发现模式,可以自动发现注册的业务服务 knife4j: gateway: enabled: true strategy: discover discover: version: openapi3 enabled: true excluded-services: - gateway 业务模块修改在上面集成seata模块的过程中,每个服务都集成knife4j的配置 测试启动4个业务服务即一个网关服务,访问网关的接口文档,发现每个业务模块都被集成了进来,如下图 测试一下接口,调用以下之前biz-web模块下的方法,发现已经正常与网关集成了 集成完毕 Rocketmq消息队列集成 服务安装参考下面另一篇文章 (324条消息) docker-compose安装 rocketmq server、dashboard_ricardo.M.Yu的博客-CSDN博客 前置准备准备两个服务:基于之前的改造:需要provider(最为生产者)以及consumer(作为消费者) 依赖 com.alibaba.cloud spring-cloud-starter-stream-rocketmq 2022.0.0.0-RC2 com.github.xiaoymin knife4j-openapi3-jakarta-spring-boot-starter Spring Cloud Stream基础因为rocketmq依赖Spring Cloud Stream,先介绍下Spring Cloud Stream。 注意,因为我们使用最新版本一来的 stream版本为最新的 4.0,需要注意3.0以后的版本,写法有很大区别,一些遗留问题,如@EnableBInding、@StreamListener都已经不再使用(deprecated) SpringCloud Stream是一个构建消息驱动微服务的框架,应用程序通过inputs或者 outputs来与SpringCloud Stream中的binder进行交互,我们可以通过配置来binding ,而 SpringCloud Stream 的binder负责与中间件交互,弄清楚两个概念: binder:Binder是SpringCloud Stream的一个抽象概念,是应用与消息中间件之间的粘合剂,目前SpringCloud Stream实现了Kafka和RabbitMQ的binder, 但是我们这里引用 rocket自己的依赖也可以实现binding :相当于定义消息级别的组、topic等信息,和binder解耦,和binders进行绑定,指定是input或output。注意: bindings:命名 格式 {name}-out-0 这是是 4.x 的一种约定 配置文件修改这边我用了两个组,两个topic来测试 provider下 bootstrap-dev.yaml,增加 rocketmq配置 spring: application: name: provider cloud: nacos: server-addr: http://192.168.1.115:8108/ discovery: group: dev #配置中心 config: server-addr: http://192.168.1.115:8108/ group: dev file-extension: yaml # 共享配置 # shared-configs: # - data-id: application-dev.yaml # group: dev # extension-configs: # - dataId: test01.yml # group: dev sentinel: transport: dashboard: 192.168.1.115:8109 port: 8900 # rocket mq 配置 stream: rocketmq: binder: name-server: 192.168.1.115:9876 bindings: test-out-0: destination: test-topic content-type: application/json group: test-group dev-out-0: destination: dev-topic content-type: application/json group: dev-groupconsumer下 bootstrap-dev.yaml,增加 rocketmq配置 spring: cloud: nacos: server-addr: http://192.168.1.115:8108/ discovery: group: dev sentinel: transport: dashboard: 192.168.1.115:9988 port: 8899 # rocket mq 配置 stream: rocketmq: binder: name-server: 192.168.1.115:9876 function: definition: test;dev bindings: test-in-0: destination: test-topic content-type: application/json group: test-group consumer: instance-count: 3 concurrency: 5 dev-in-0: destination: dev-topic content-type: application/json group: dev-group consumer: instance-count: 3 concurrency: 5 业务代码写一个person的测试类 @Data public class Person { private String name; } providercontroller @RestController @Tag(name = "消息-消息队列发送") @RequestMapping("/message/send") public class MqSendController { @Resource private MqSendService mqSendService; @Operation(summary = "发送") @PostMapping public void send(@RequestParam String channel, @RequestParam String message) { mqSendService.send(channel, message); } }service @Service public class MqSendService { @Resource private StreamBridge streamBridge; public void send(String channel, String message) { Person person = new Person(); person.setName(message); Message build = MessageBuilder.withPayload(person).build(); streamBridge.send(channel, build); } } consumerservice @Slf4j @Service public class MqSubService { @Bean public Consumer test() { return message -> { MessageHeaders headers = message.getHeaders(); Person payload = message.getPayload(); log.info("消息 test:" + payload + "__" + headers); }; } @Bean public Consumer dev() { return message -> { MessageHeaders headers = message.getHeaders(); Person payload = message.getPayload(); log.info("消息 dev:" + payload + "__" + headers); }; } } 测试调用provider的controller方法, 注意,channel必须和配置文件里面的 destination 一致,否则收不到消息。 consumer打印: web界面 已经正常集成完毕。 进阶 消息丢失问题几个问题,一个是多组多订阅的问题,即一个组下的consumer订阅的topic要一直,不然消费组订阅关系不一致,会导致消息丢失问题,下面这个文章结束的比较好 RocketMQ的tag还有这个“坑”! - 知乎 (zhihu.com) tag与key的设置通过 stream 的header设置,来设置这两个参数 public void send(String channel, String message, String tag, String keys) { Person person = new Person(); person.setName(message); Message build = MessageBuilder.withPayload(person) .setHeader(MessageConst.PROPERTY_TAGS, tag).setHeader(MessageConst.PROPERTY_KEYS, keys).build(); streamBridge.send(channel, build); }可以看到,这两个参数已经被设置上 Sleuth+Zipkin集成分布式链路追踪Zipkin是Twitter开源的分布式实时数据跟踪系统,主要功能是收集系统的时序数据,从而追踪微服务架构的系统延时等问题,从而达到链路调用监控跟踪作用,还提供了一个非常友好的UI界面,来帮助分析追踪数据。 zipkin可视化服务安装安装的链接在这里 (291条消息) docker-compose 搭建 zipkin 服务端_ricardo.M.Yu的博客-CSDN博客 业务集成事先没做调研,从maven仓库选择了个最新的依赖 org.springframework.cloud spring-cloud-starter-zipkin 2.2.8.RELEASE修改 bootstrap-dev.yaml 增加配置, zipkin: base-url: http://192.168.1.115:8112/ sender: type: web enabled: true sleuth: sampler: probability: 1 问题及大坑启动后 看着有点变化,测试后没用,一通找文档 最后到了官方文档 Spring Cloud Sleuth Reference Documentation sleuth停止支持, springboot 3.0.x之后的版本已经不再支持了, Spring Cloud Sleuth will not work with Spring Boot 3.x onward. The last major version of Spring Boot that Sleuth will support is 2.x. 待寻找其他方案。 Micrometer Tracing 集成实现分布式链路追踪springboot 3.0.x之后,官方移除了对 sleuth的支持,将可观测性这部分迁移到了 Micrometer 项目中,下面实现这部分的功能,通过 Micrometer Tracing 实现日志以及通过 zipkin实现收集。 资料Micrometer Tracing官方文档 Micrometer Application Observability sleuth迁移官方文档 Spring Cloud Sleuth 3.1 Migration Guide · micrometer-metrics/tracing Wiki (github.com) 集成 依赖需要下面的几个依赖 引入依赖管理器 1.1.1 io.micrometer micrometer-tracing-bom ${micrometer-tracing.version} pom import需要用到的依赖 io.micrometer micrometer-tracing-bridge-brave io.zipkin.reporter2 zipkin-reporter-brave org.springframework.boot spring-boot-starter-actuator 配置修改基于之前biz模块下面的4个应用,都增加如下配置 management: tracing: sampling: probability: 1.0 zipkin: tracing: endpoint: http://192.168.1.115:8112/api/v2/spans connect-timeout: 3s logging: pattern: level: ${spring.application.name:},%X{traceId:-},%X{spanId:-} %5p注意: endpoint为zipkin配置 格式配置必须要为: http://{ip:port}/api/v2/spans,详见ZipkinProperties 日志格式为 应用名+ traceId +spanId 测试服务起来之后,还是调用biz-web下面的 接口,控制台输出的日志格式如下: 查看 zipkin的控制台已经能看到日志的收集 Spring Boot Admin 集成实现服务监控功能:集成以实现健康 (Health)信息、内存信息、JVM 系统和环境属性、垃圾回收信息、日志设置和查看、定时任务查看、Spring Boot 缓存查看和管理等功能 前置准备准备两个服务,一个是 admin server端,另一个用来做客户端监控 配置修改 父工程 3.0.4 de.codecentric spring-boot-admin-starter-server ${spring.boot.admin.version} de.codecentric spring-boot-admin-starter-client ${spring.boot.admin.version} admin工程pom com.sy common 1.0-SNAPSHOT de.codecentric spring-boot-admin-starter-server配置文件 server: port: 9002 spring: application: name: admin management: endpoint: health: show-details: always 客户端consumerpom de.codecentric spring-boot-admin-starter-client配置文件 spring: application: name: consumer boot: admin: client: url: http://localhost:9002 management: endpoint: health: show-details: always endpoints: web: exposure: include: ["*"] 测试分别启动两个服务,访问 admin的web界面 http://localhost:9002/ 效果已经成功启动,并且可以看见两个实例 点击应用墙 查看 consumer实例详情 可以看到更多详细配置 至此,集成完毕 集成Spring Authorization Server 与Spring Security Oauth2.1统一认证 过程这块整体比较复杂,我专门开了一篇新文章,专门介绍概念与集成,链接在下面 (305条消息) Spring Security Oauth2.1 最新版 1.1.0 整合 (基于 springboot 3.1.0)gateway 完成授权认证_ricardo.M.Yu的博客-CSDN博客 |
CopyRight 2018-2019 实验室设备网 版权所有 |